package com.jfree.listener;

import com.jfree.source.TestMessageSource;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

@EnableBinding(value = {TestMessageSource.class})
public class TestListener {

    @StreamListener(TestMessageSource.INPUT)
    public void receive(String playload){
        System.out.println("-----"+playload+"---");

    }
}
